package com.visec.hdy.hadoop.analysis;

import java.io.InputStream;

/**
 * 时间分析实现类
 * 
 * @author hdy
 *
 * @param <V>
 */
public class FileAnalysisImpl<V> extends DefaultAnalysisImpl<String, V, InputStream> {

	protected String target;

	public FileAnalysisImpl(String key,String target) {
		super(key);
		this.target=target;
	}

	@Override
	public com.visec.hdy.hadoop.standard.Analysis.Item<String, InputStream> analyze(V value) {
		return new Item<>(reflexField(key, value).toString(), (InputStream) reflexField(target, value));
	}

}
